package com.qyer.commons.kafka;

import org.apache.kafka.common.TopicPartition;

/**
 * User: Z J Wu Date: 2016/06/28 Time: 18:44 Package: com.qyer.pushengine.ios.model
 */
public class PartitionAssignment {

  private volatile TopicPartition[] assignment;

  public PartitionAssignment() {
  }

  public TopicPartition[] getAssignment() {
    return assignment;
  }

  public void setAssignment(TopicPartition[] assignment) {
    this.assignment = assignment;
  }
}
